/**
 * 版权所有(C)，上海***股份有限公司，2018，所有权利保留。
 * 
 * 项目名：	rabbitmq
 * 文件名：	ConnectionUtil.java
 * 模块说明：	
 * 修改历史：
 * 2018年9月27日 - Administrator - 创建。
 */
package com.study.rabbitmq.util;

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * @author Administrator
 *
 */
public class ConnectionUtil {

  public static Connection getConnection() throws Exception {
    // 定义连接工厂
    ConnectionFactory factory = new ConnectionFactory();
    // 设置服务地址
    factory.setHost("localhost");
    // 端口
    factory.setPort(5672);
    // 设置账号信息，用户名、密码、vhost
    factory.setVirtualHost("/");
    factory.setUsername("rabbitmq");
    factory.setPassword("rabbitmq");
    // 通过工程获取连接
    return factory.newConnection();
  }
}
